/*
 * 文件名： VinPartitioner.java
 * 
 * 创建日期： 2017年2月24日
 *
 * Copyright(C) 2017, by <a href="mailto:liws@xingyuanauto.com">liws</a>.
 *
 * 原始作者: liws
 *
 */
package com.moli.iov.gateway.util.Partitioner;


/**
 * 根据VIN码 进行车辆Topic分区
 *
 * @author <a href="mailto:liws@xingyuanauto.com">liws</a>
 *
 * @version $Revision$
 *
 * @since 2017年2月24日
 */
public class VinQueuePartitioner implements Partitioner {

	@Override
	public int partition(Object key, int numPartitions) {
		int hCode = key.hashCode();
		int partitionIndex = Math.abs(hCode)%numPartitions;
		return partitionIndex;
	}

}
